package com.init;

import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;

import com.activeMQ.InitMqBrokerRegBean;

public class InitJms implements ApplicationListener<ContextRefreshedEvent> {

	/***
	 * 在spring容器启动完成之后获取配置中心mq 的相关的配置 用于启动 添加相关的实例
	 */
	@Override
	public void onApplicationEvent(ContextRefreshedEvent event) {
		if (event.getApplicationContext().getParent() == null) {
			// 需要执行的逻辑代码，当spring容器初始化完成后就会执行该方法。

			try {

				/***
				 * 初始化bean
				 */

				InitMqBrokerRegBean initMqBrokerRegBean = new InitMqBrokerRegBean();
				initMqBrokerRegBean.initBean();
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
	}

}
